const { Controller } = require("egg");

class ChatController extends Controller {
  async init(){
    const { ctx, app } = this;
    const message = ctx.args[0];
    app.emit("chat", message);
  }
  // 接收用户端传来的消息
  async getUserMessage() {
    const { ctx, app } = this;
    const message = ctx.args[0];
    // 发送给后台管理员
    app.io.to("adminRoom").emit("adminChat", message)
    console.log("用户发来消息：", message);
  }
  // 接收后台管理员传来的消息
  async getAdminMessage() {
    const { ctx, app } = this;
    const message = ctx.args[0];
    const {userId,...assets} = message;
    // 发送给用户
    app.io.to(userId).emit("wxChat", assets)
    console.log("后台管理员发来消息：", message);
  }
}
module.exports = ChatController;
